b454af427e0f50c1110d53ddfa7ef450a6f61863,src/main/java/io/hgraphdb/HBaseBulkLoader.java,HBaseBulkLoader,HBaseBulkLoader,#HBaseGraph#,35

Before Change


        try {
            this.graph = graph;

            BufferedMutator.ExceptionListener listener = (e, mutator) -> {
                for (int i = 0; i < e.getNumExceptions(); i++) {
                    LOGGER.warn("Failed to send put: " + e.getRow(i));
                }
            };

            HBaseGraphConfiguration config = graph.configuration();

            BufferedMutatorParams edgesMutatorParams =
                    new BufferedMutatorParams(HBaseGraphUtils.getTableName(config, Constants.EDGES)).listener(listener);
            BufferedMutatorParams edgeIndicesMutatorParams =
                    new BufferedMutatorParams(HBaseGraphUtils.getTableName(config, Constants.EDGE_INDICES)).listener(listener);
            BufferedMutatorParams verticesMutatorParams =
                    new BufferedMutatorParams(HBaseGraphUtils.getTableName(config, Constants.VERTICES)).listener(listener);
            BufferedMutatorParams vertexIndicesMutatorParams =
                    new BufferedMutatorParams(HBaseGraphUtils.getTableName(config, Constants.VERTEX_INDICES)).listener(listener);

            edgesMutator = graph.connection().getBufferedMutator(edgesMutatorParams);
            edgeIndicesMutator = graph.connection().getBufferedMutator(edgeIndicesMutatorParams);
            verticesMutator = graph.connection().getBufferedMutator(verticesMutatorParams);
            vertexIndicesMutator = graph.connection().getBufferedMutator(vertexIndicesMutatorParams);

            skipWAL = config.getBulkLoaderSkipWAL();
        } catch (IOException e) {

After Change


        this(new HBaseGraph(config, HBaseGraphUtils.getConnection(config)));
    }

    public HBaseBulkLoader(HBaseGraph graph) {
        this(graph,
                getBufferedMutator(graph, Constants.EDGES),
                getBufferedMutator(graph, Constants.EDGE_INDICES),
                getBufferedMutator(graph, Constants.VERTICES),
                getBufferedMutator(graph, Constants.VERTEX_INDICES));
    }

    private static BufferedMutator getBufferedMutator(HBaseGraph graph, String tableName) {